
const mysql = require("mysql")

// 创建一个链接对象
let host = {
  host: "112.74.108.161",
  user: "root",
  password: "123456",
  database: "red",
}
let local = {
  host: "127.0.0.1",
  user: "root",
  password: "123456",
  database: "red",
}
// 通过链接对象执行链接
function myConnect(conn) {
  conn.connect((err) => {
    if (err) {
      console.log("连接" + err.message);
    } else {
      // console.log("连接数据库成功");
    }
  })
}

function myEnd(conn) {
  // console.log("开始关闭");
  conn.end((err) => {
    if (err) {
      console.log("关闭" + err.message);
    } else {
      // console.log("关闭数据库成功");
    }
  })
}

async function myQuery(SQL, callback, params=[]) {
  let conn = mysql.createConnection(local);
  myConnect(conn)
  conn.query(SQL, params, async (err, result) => {
    if (err) {
      console.log("查询" + err.message);
    } else {
      // 回调函数
      await callback(result)
      // console.log("执行完成");
      myEnd(conn)
    }
  })
}

module.exports = myQuery